package cc.rboot.topic.core;

public interface IMessageProcessor<T> {

    void register(IMessageConsumer<T> consumer);

    void send(T message) throws Exception;

    String getTopic();

    public void setTopic(String topic);
}